package com.xhx.stream.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 消费者通道接口
 * 
 * @author xhx
 */
public interface CustomSinkChannel {
	String FACE_INPUT = "face_input";
	String HUMAN_INPUT = "human_input";
	String VEHICLE_INPUT = "vehicle_input";
	String LOG_INPUT = "log_input";

	@Input(FACE_INPUT)
	SubscribableChannel faceInput();

	@Input(HUMAN_INPUT)
	SubscribableChannel humanInput();

	@Input(VEHICLE_INPUT)
	SubscribableChannel vehicleInput();

	@Input(LOG_INPUT)
	SubscribableChannel logInput();
}